org.springframework.messaging.tcp

Interface TcpOperations<P>

Type Parameters:

P - the type of payload for in and outbound messages

All Known Implementing Classes:

Reactor11TcpClient, ReactorTcpClient

public interface TcpOperations<P>

A contract for establishing TCP connections.

Since:

4.0

Author:

Rossen Stoyanchev

Method Summary

Modifier and Type	Method and Description
ListenableFuture<java.lang.Void>	connect(TcpConnectionHandler<P> connectionHandler) Open a new connection.
ListenableFuture<java.lang.Void>	connect(TcpConnectionHandler<P> connectionHandler, ReconnectStrategy reconnectStrategy) Open a new connection and a strategy for reconnecting if the connection fails.
ListenableFuture<java.lang.Boolean>	shutdown() Shut down and close any open connections.

Method Detail

connect

ListenableFuture<java.lang.Void> connect(TcpConnectionHandler<P> connectionHandler)

Open a new connection.

Parameters:

connectionHandler - a handler to manage the connection

Returns:

a ListenableFuture that can be used to determine when and if the connection is successfully established

connect

ListenableFuture<java.lang.Void> connect(TcpConnectionHandler<P> connectionHandler,
                                         ReconnectStrategy reconnectStrategy)

Open a new connection and a strategy for reconnecting if the connection fails.

Parameters:

connectionHandler - a handler to manage the connection

reconnectStrategy - a strategy for reconnecting

Returns:

a ListenableFuture that can be used to determine when and if the initial connection is successfully established

shutdown

ListenableFuture<java.lang.Boolean> shutdown()

Shut down and close any open connections.

Returns:

a ListenableFuture that can be used to determine when and if the connection is successfully closed